package kproduct

import (
	"context"
	"github.com/Shopify/sarama"
	"log"
)

const UseNilMetrics = true

type KafkaProducer interface {
	Close()
	SetLogger(logger *log.Logger)
	Start(ctx context.Context) error
	SendMessage(msg *sarama.ProducerMessage) (partition int32, offset int64, err error)
	SendMessages(msgs []*sarama.ProducerMessage) error
}
